package com.pipe.connector;

import com.pipe.protocol.events.write.WriteRowEventV2Rows;

/**
 * @author Kiven
 */
public interface RowDataListener {

    /***
     * 当有新的insert或update数据到来时触发此方法
     * @param rows
     */
    void newDataArrived(WriteRowEventV2Rows rows);
}